package com.cy.tempflinkcdc.controller;



import cn.hutool.core.io.FileUtil;
import com.cy.tempflinkcdc.util.ZipUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.*;
import java.sql.SQLException;
import java.text.SimpleDateFormat;



/**
 * @author asus
 * @version 1.0
 * @description: TODO
 * @date 2024/9/26 16:34
 */
@Slf4j
@RestController
@RequestMapping("/zip")
public class zipController {


    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmm");
    private static String currentFileName;
    private static BufferedWriter writer;
    /**
    * @description:
    * @author fileToZip 文件路径   outputZipFile 生成压缩包的路径
    * @date 2024/9/26 19:18
    * @version 1.0
    */
    //@RequestParam String fileToZip,
    //@RequestParam String outputZipFile

    //
    // @GetMapping("/zipPack")
    // @Scheduled(fixedRate =60*1000) // 每 分钟执行一次
    // public void zipPack() throws IOException {
    //
    //     long currentTime = System.currentTimeMillis();
    //
    //     //延迟
    //     long twentyMinutesInMillis =  70 * 1000;
    //     currentTime = currentTime - twentyMinutesInMillis;
    //
    //     String newFileName = dateFormat.format(new Date(currentTime));
    //
    //     String needZipFile = "/root/sql/" + newFileName + ".sql";
    //      log.info("需要压缩的文件：{}", needZipFile);
    //       singleDeflateZip(new File(needZipFile), "12345");
    //      //将文件 ftp
    //     postFile(needZipFile+".zip");
    //     log.info("{} 文件 FTP服务器 推送成功",needZipFile+".zip");
    //
    // }


    // public static String logfile = "E:\\root2\\";
    public static String logfile  ="/root/sql/";

    // @GetMapping("/recordMysqlBinlog")
    // @Scheduled(fixedDelay  =60*1000) // 每 分钟执行一次
    // public void recordMysqlBinlog() throws IOException {
    //
    //     //先判断文件在不在，在的话，取回来追加当前的内容，在发一次
    //     // long currentTime = System.currentTimeMillis();
    //     // String newFileName = dateFormat.format(new Date(currentTime));
    //     // postFileOrAppend(logfile+newFileName+".sql");
    //     //
    //     //
    //     for (File file : new File(logfile).listFiles()) {
    //         postFile(file.getAbsolutePath());
    //     }
    //
    //
    //     log.info("binlog推送成功");
    //
    // }



}
